package com.wande.dataplatform.domain;

import com.baomidou.mybatisplus.annotation.*;
import com.wande.common.mybatis.core.domain.BaseEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;

import java.io.Serial;

/**
 * ETL任务实体
 *
 * @author dataplatform
 */
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("dp_etl_task")
public class EtlTask extends BaseEntity {

    @Serial
    private static final long serialVersionUID = 1L;

    /**
     * 主键ID
     */
    @TableId(value = "id", type = IdType.AUTO)
    private Long id;

    /**
     * 租户ID
     */
    private Long tenantId;

    /**
     * ETL任务名称
     */
    private String name;

    /**
     * 任务类型: FULL-全量, INCREMENTAL-增量
     */
    private String taskType;

    /**
     * 源数据源ID
     */
    private Long sourceId;

    /**
     * 目标数据源ID
     */
    private Long targetId;

    /**
     * 源配置JSON
     */
    private String sourceConfig;

    /**
     * 目标配置JSON
     */
    private String targetConfig;

    /**
     * 转换配置JSON
     */
    private String transformConfig;

    /**
     * 调度配置JSON
     */
    private String scheduleConfig;

    /**
     * DolphinScheduler工作流ID
     */
    private Long dsWorkflowId;

    /**
     * 状态: 0-禁用, 1-启用
     */
    private Integer status;

    /**
     * 所属项目ID
     */
    private Long projectId;
}
